package com.example.study.commen.commenutils;

import com.alibaba.fastjson.JSONObject;
import com.example.study.config.redis.RedisUtil;
import org.springframework.beans.factory.annotation.Autowired;

public class CdcDataProcessCache {

    /**
     * 临时写入缓存
     */
    private void CdcDataProcessCache(JSONObject result, RedisUtil redisUtil) {

        if (result.getString("db").equals("study")) {
            if (result.getString("tableName").equals("token_user")) {
                switch (result.getString("op")) {
                    case "UPDATE":
//                        log.info("xxxxxxxxxx"+redisUtil.get("categroy::findTokenByUserName").toString());

                        break;
                    case "CREATE":

                        break;
                    case "DELETE":

                        break;
                }
            }
        }

    }

}
